package com.innodealing.constants;

/**
 * Kafka相关常量
 * 
 * @author 系统生成
 * @date 2024/12/18
 */
public final class KafkaConstants {
    
    private KafkaConstants() {
        // 私有构造函数，防止实例化
    }
    
    /**
     * Topic名称
     */
    public static final class Topics {
        public static final String USER_EVENTS = "user_events";
        
        private Topics() {}
    }
    
    /**
     * Consumer Group ID
     */
    public static final class ConsumerGroups {
        public static final String USER_EVENTS_GROUP = "flink_user_events";
        
        private ConsumerGroups() {}
    }
    
    /**
     * 源名称
     */
    public static final class SourceNames {
        public static final String USER_EVENTS_SOURCE = "User Events Kafka Source";
        
        private SourceNames() {}
    }
} 